import requests,time,sys,re

import urllib,zlib
import pymysql

import unittest
from trace import CoverageResults
import json
from idlelib.rpc import response_queue
from ETP.celery import app
from ETP.Services.Actuator import Actuator

from time import sleep
import logging
logger = logging.getLogger(__name__)
collect_logger = logging.getLogger("collect")

@app.task
def hello_word():
    time.sleep(60)
    print('已运行')


@app.task
def runMysuite(suiteID):
    logger.info('---------开始异步运行测试套件执行------------->>>>>')
    actuator = Actuator()
    actuator.run_suite(suiteID)
    logger.info('---------异步运行测试套件执行结束-------------<<<<<')